# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.operators.bash import BashOperator
from jms.dm.dm_sham_send_monitor_detail_dt_res_h9 import jms_dm__dm_sham_send_monitor_detail_dt_res_h9

jms_oracle__dm_sham_send_monitor_detail_dt_h9 = BashOperator(
    task_id='jms_oracle__dm_sham_send_monitor_detail_dt_h9',
    execution_timeout=timedelta(hours=2),
    email=['yl_etl@yl-scm.com','suning@jtexpress-scm.com'],
    bash_command="jms/oracle/dm_sham_send_monitor_detail_dt_h9/execute.sh",
    pool='spmi_apack',
    retries=1,
    pool_slots=2,
)

jms_oracle__dm_sham_send_monitor_detail_dt_h9 <<[jms_dm__dm_sham_send_monitor_detail_dt_res_h9]